package com.etl.dataflow.executor.core;


import com.etl.dataflow.executor.element.Row;

import java.util.List;

/**
 * @author dx
 * @since 2022/4/14
 */
public interface ChannelWriter {
    void writeOneRow(Row row);

    void terminate();

    void shutdown();
}
